package com.zhf.consumer.springboot;

import org.json.JSONObject;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @author: 曾鸿发
 * @create: 2022-01-09 20:19
 * @description：
 **/
@Component
public class RabbitMQListener {

    // 定义方法进行信息的监听  RabbitListener 中的参数用于表示监听的是哪一个队列
    @RabbitListener(queues = "boot_queue")
    public void listenerQueue(Message message){
        System.out.println("message:" + message);
    }
}
